package com.task.web.controller.core;

import cn.hutool.core.util.IdUtil;
import com.task.common.core.controller.BaseController;
import com.task.common.core.domain.AjaxResult;
import com.task.common.core.redis.RedisCache;
import com.task.common.redis.RedisKeyConstants;
import com.task.core.service.DataNoticeService;
import io.swagger.annotations.Api;
import org.springframework.util.ObjectUtils;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;

import javax.annotation.Resource;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;


@Api("统一通知")
@RestController
@RequestMapping("/notice")
public class DataNoticeController extends BaseController {


    @Resource
    private DataNoticeService noticeService;


//    @GetMapping("/getDataSourceSubscribe")
//    public SseEmitter dataSourceSubscribe(@RequestParam("sourseCode") String sourseCode)  {
//        SseEmitter sseEmitter = noticeService.crateSse(sourseCode);
//        return sseEmitter;
//    }


}
